package com.jx.springcloud.controller;




import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.stream.annotation.StreamListener;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.messaging.Message;

import javax.annotation.Resource;

@EnableBinding(Sink.class)
public class StreamReceiveMessages {
    @Value("${server.port}")
    private String port;

    @StreamListener(Sink.INPUT)
    public void receiveMessage(Message<String> message){
        System.out.println(" 消费者2号——————>"+ message.getPayload() + "   端口号： "+port);
    }
}
